package com.xqls.quaz;


import com.xqls.dal.service.DeviceSchemaMapper;
import com.xqls.thread.ThreadPoolExecutorUtil;
import com.xqls.util.ContextUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.Callable;

public class AmgJob {
	@Value("${deviceSchema}")
    private String deviceSchema;
	@Value("${deviceType}")
    private String deviceType;
    private static final Logger LOG = LoggerFactory
            .getLogger(AmgJob.class);
    @Autowired
    DeviceSchemaMapper deviceSchemaMapper;

    public void alarmMessage(){
        new AlarmMessageRunAble(deviceType).call();

    }
}
